244ee83be8c1180ea1845b8768503c8013b0dc7f,opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/NormalizedNodeStreamReaderWriterTest.java,NormalizedNodeStreamReaderWriterTest,testNormalizedNodeStreaming,#,52
Before Change
.withNodeIdentifier(new NodeIdentifier(SchemaContext.NAME)).withChild(toasterNode).build();
writer.writeNormalizedNode(toasterContainer);
NormalizedNodeInputStreamReader reader = new NormalizedNodeInputStreamReader(
ByteStreams.newDataInput(byteArrayOutputStream.toByteArray()));
NormalizedNode<?,?> node = reader.readNormalizedNode();
Assert.assertEquals(testContainer, node);
After Change
public void testNormalizedNodeStreaming() throws IOException {
ByteArrayOutputStream bos = new ByteArrayOutputStream();
NormalizedNodeDataOutput nnout = NormalizedNodeInputOutput.newDataOutput(ByteStreams.newDataOutput(bos));
NormalizedNode<?, ?> testContainer = createTestContainer();
nnout.writeNormalizedNode(testContainer);
QName toaster = QName.create("http://netconfcentral.org/ns/toaster","2009-11-20","toaster");
QName darknessFactor = QName.create("http://netconfcentral.org/ns/toaster","2009-11-20","darknessFactor");
QName description = QName.create("http://netconfcentral.org/ns/toaster","2009-11-20","description");
ContainerNode toasterNode = Builders.containerBuilder().withNodeIdentifier(new NodeIdentifier(toaster))
.withChild(ImmutableNodes.leafNode(darknessFactor, "1000"))
.withChild(ImmutableNodes.leafNode(description, largeString(20))).build();
ContainerNode toasterContainer = Builders.containerBuilder()
.withNodeIdentifier(new NodeIdentifier(SchemaContext.NAME)).withChild(toasterNode).build();
nnout.writeNormalizedNode(toasterContainer);
NormalizedNodeDataInput nnin = NormalizedNodeInputOutput.newDataInput(ByteStreams.newDataInput(
bos.toByteArray()));
NormalizedNode<?,?> node = nnin.readNormalizedNode();
Assert.assertEquals(testContainer, node);